package org.apache.dolphinscheduler.api.service;



import com.alibaba.fastjson.JSONArray;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;

import java.util.Map;

public interface OutputInfoService {
    Map<String,Object> getColumnInfo(int nodeId,int point);
    Map<String,Object> getList(int nodeId,int point);
    Map<String, Object> getXYList(int nodeId, int point, String[] X, String[] Y);
    void delByProcessInstanceId(int processInstanceId);
    void delByProcessDefinitionId(int processDefinitionId);
    void saveOutputInfo(Dataset<Row> dataset, int nodeId);
}
